
 /**
 * 上海中赢金融信息服务有限公司
 * Copyright (c) 2017, chinazyjr All Rights Reserved.
 */
package com.sys.kafka.samples;

import com.sys.kafka.core.consumer.IConsumerHandler;
import com.sys.kafka.factory.ConsumerFactory;

/**
 * <b>Description：</b> TODO <br/>
 * <b>ClassName：</b> SmsMessageFacade <br/>
 * <b>@author：</b> mobing <br/>
 * <b>@date：</b> 2017年7月17日 上午10:39:32 <br/>
 * <b>@version: </b>  <br/>
 */
public class SmsMessageFacade {
    private boolean isStarted =false;
    IConsumerHandler handler= ConsumerFactory.getInstance();
    public void start(){
        if(isStarted){
            return;
        }
       handler.subscribe("test");
       
       handler.register("test",new SmsMessageListener());
       
        isStarted =true;
        
    }
    
}
